c847205fcc35b16b534ed3ab21f31e1fff3e9eea,src/test/java/org/springframework/integration/dsl/test/manualflow/ManualFlowTests.java,ManualFlowTests,testDynamicSubFlow,#,147
Before Change
public void testDynamicSubFlow() {
PollableChannel resultChannel = new QueueChannel();
this.integrationFlowContext.register("dynamicFlow", flow -> flow
.publishSubscribeChannel(p -> p
.minSubscribers(1)
.subscribe(f -> f.channel(resultChannel))
));
this.integrationFlowContext.messagingTemplateFor("dynamicFlow").send(new GenericMessage<>("test"));
After Change
public void testDynamicSubFlow() {
PollableChannel resultChannel = new QueueChannel();
this.integrationFlowContext.registration(flow ->
flow.publishSubscribeChannel(p -> p
.minSubscribers(1)
.subscribe(f -> f.channel(resultChannel))
))
.id("dynamicFlow")
.register();
this.integrationFlowContext.messagingTemplateFor("dynamicFlow").send(new GenericMessage<>("test"));